草庐IT

python - 解析 Redis MONITOR 消息

全部标签

elasticsearch - 并发文件解析并插入到 Elastic Search 中

我最近在玩Go,想出了一个小脚本来解析日志文件并将它们插入到Elasticsearch中。对于每个文件,我都生成了一个这样的goroutine:varwg:=sync.WaitGroup{}wg.Add(len(files))for_,file:=rangefiles{gofunc(fos.FileInfo){deferwg.Done()ProcessFile(f.Name(),config.OriginFilePath,config.WorkingFilePath,config.ArchiveFilePath,fmt.Sprintf("http://%v:%v",config.Ela

regex - Go:处理多行命令输出并解析

我正在尝试从命令行实用程序中提取信息,在本例中是linuxntpq-crv命令。输出:associd=0status=0638leap_none,sync_ntp,3events,no_sys_peer,version="ntpd4.2.6p5@1.2349-oFriJul2217:30:51UTC2016(1)",processor="x86_64",system="Linux/3.16.0-4-amd64",leap=00,stratum=2,precision=-22,rootdelay=25.435,rootdisp=49.398,refid=8.8.8.8,reftime=d

javascript - 到特定房间的 Websocket 消息 - Golang Kataras/Iris

我正在尝试向特定房间发送消息,但它不起作用,它向所有房间发送消息,同时我的消息从我的名字和第一个聊天室用户名收到两次。来自1个房间的消息被广播到所有聊天室。我使用了此处的示例代码-https://github.com/kataras/iris/blob/master/_examples/websocket/secure/main.go.和https://github.com/kataras/iris/blob/master/_examples/websocket/native-messages/main.go下面是我正在使用的代码,它给我错误:varmyChatRoom=strconv

go - Zap 堆栈跟踪与谷歌云上的错误消息

我正在使用zapp在谷歌云上托管的服务上记录错误消息,我看到虽然成功记录了错误,但存储在谷歌云日志“消息”字段中的文本是堆栈跟踪,并且不是我记录的错误消息。示例代码:varlog*zap.Loggeriferr:=doStuff();err!=nil{log.Error(,zap.Error(err))}除了谷歌云日志记录和堆栈驱动程序将使用调用结构化日志的message字段中的zap.Error捕获的堆栈跟踪外,这工作得很好。我定义的消息出现在msg字段中,但前者似乎是主要显示在日志记录控制台中并被stackdriver用于索引错误的消息。这意味着当通过控制台浏览日志和错误时,我只能

go - 如何通过 AMQP 1.0 在 Azure Event Hub 中批量接收多条消息

我使用QpidProton的ApacheQpidElectronGo包装器设置了一个仅包含路径和过滤器的AMQP1.0链接,如下所示:amqpConnection.Receiver(//thepathcontainingtheconsumergroup//andthepartitionIdelectron.Source(""),//thefiltermapcontainssomeannotationsfilters//fortheEventHuboffsetelectron.Filter(filterMap),)我按照此文档设置了AMQP链接选项:https://godoc.org/q

go - 在 GO 中解析时间时出现奇怪的错误消息

我尝试在go中将字符串解析为时间,这是我所做的:dateTime:=fmt.Sprintf("%s%sCST",dateValue,timeValue)date,err:=time.Parse("2006-1-2150405MST",dateTime)我收到以下错误信息:解析时间“2012-4-9174031CST”为“2006-1-2150405MST”:无法将“2012-4-9174031CST”解析为“2006”从报错信息来看,我传入的dateTime值是正确的。我还尝试执行以下操作,效果很好:dateTime:="2012-4-9174031CST"date,err:=time

python - uWSGI + 构建 Go .so 不工作

问题:.so(共享对象)作为python中的库在python调用它时运行良好,但在运行uWSGI的python(Django)应用程序中失败。更多信息:我已经使用gobuild-buildmode=c-shared-ooutput.soinput.go构建了Go模块,以便在Python中调用它fromctypesimportcdlllib=cdll.LoadLibrary('path_to_library/output.so')当通过uWSGI提供django项目时,调用Go库的请求处理程序卡住,导致Nginx中的future504。在进入“所谓的卡住”后,uWSGI被锁定在那里,只有

go - emersion/go-imap - 如何检索和列出看不见的消息

我正在尝试使用IMAP协议(protocol)的实现,但似乎无法从邮箱中检索看不见的邮件。这是我的代码。packagemainimport("emailmonitor/util""fmt")funcmain(){serverGmail:=util.NewServerGmail()serverGmail.Connect()serverGmail.Login()serverGmail.ListUnseenMessages()}//-----------------------------------------packageutilimport("io/ioutil""log""net/m

regex - 解析参数列表中以逗号分隔的逗号分隔值

所以我有这个正则表达式:=([0-9A-Za-z_-]+),?我需要一个像这样的字符串:foo=bar,pine=apple,tree,bar=bieorfoo=bar,pine=apple,treeorpine=apple,tree正则表达式适用于我只有1个值的情况。但是因为我们在键的值列表中有逗号。正则表达式只是乱码,我的代码完成了我想要它做的一半,但没有获得第二个值。我如何修复我的正则表达式以获取两个值,而不管它在字符串中的位置?单独,在另外2个之间,最后。我尝试了一些东西,但无法弄明白。尝试1:=([0-9A-Za-z,_-]+),=?在这种情况下,它匹配它在中间的那个,但它在

Golang 解析数组

我想弄清楚为什么我的代码不起作用。我想取一片数字和字符串,并将其分成三片。对于slice中的每个元素,如果是字符串,则将其追加到字符串slice中,如果是正数,则将其追加到正数中,负数也一样。然而,这是输出姓名:埃夫特伦布莱45.39934611083154-75.71148292845268[Crestview-75.73795670904249贝尔维庄园-75.73886856878032Dutchie'sHole-75.66809864107668...正数:[45.34438763292405445.37223315413918...]否定:[]这是我的代码。谁能告诉我是什么导